ed8babb97408a8af3ed3aa38985da00f86ce0065,core/src/main/java/org/elasticsoftware/elasticactors/cluster/LocalActorShard.java,LocalActorShard,undeliverableMessage,#InternalMessage#,124

Before Change


    @Override
    public void undeliverableMessage(InternalMessage message) throws Exception {
        // get the durable flag
        Message messageAnnotation = Class.forName(message.getPayloadClass()).getAnnotation(Message.class);
        final boolean durable = (messageAnnotation != null) && messageAnnotation.durable();
        // input is the message that cannot be delivered
        InternalMessage undeliverableMessage;
        if (message instanceof InternalMessageImpl) {
            undeliverableMessage = new InternalMessageImpl( message.getReceiver(),
                                                            message.getSender(),
                                                            message.getPayload(),
                                                            message.getPayloadClass(),

After Change


                                                            message.getSender(),
                                                            message.getPayload(),
                                                            message.getPayloadClass(),
                                                            message.isDurable(),
                                                            true);
        }
        messageQueue.offer(undeliverableMessage);